# -*- coding: utf-8 -*-
from datetime import timedelta

from airflow.operators.dummy_operator import DummyOperator

# from jms.doris.jms_dwd.dwd_route_whole.inbranch import doris_jms_dwd__dwd_route_whole_from_whole_inbranch
from jms.dm.route.dm_route_whole_base_dt import dm__dm_route_whole_base_dt
from jms.doris.jms_dwd.dwd_route_whole.dongbei import doris_jms_dwd__dwd_route_whole_from_whole_dongbei
from jms.doris.jms_dwd.dwd_route_whole.huabei import doris_jms_dwd__dwd_route_whole_from_whole_huabei
from jms.doris.jms_dwd.dwd_route_whole.huadong import doris_jms_dwd__dwd_route_whole_from_whole_huadong
from jms.doris.jms_dwd.dwd_route_whole.huanan import doris_jms_dwd__dwd_route_whole_from_whole_huanan
from jms.doris.jms_dwd.dwd_route_whole.huaxi import doris_jms_dwd__dwd_route_whole_from_whole_huaxi
from jms.doris.jms_dwd.dwd_route_whole.huazhong import doris_jms_dwd__dwd_route_whole_from_whole_huazhong
from jms.doris.jms_dwd.dwd_route_whole.local_city import doris_jms_dwd__dwd_route_whole_from_local_city
from jms.doris.jms_dwd.dwd_route_whole.xibei import doris_jms_dwd__dwd_route_whole_from_whole_xibei
from jms.doris.jms_dwd.dwd_route_whole.xinan import doris_jms_dwd__dwd_route_whole_from_whole_xinan

doris_jms_dwd__route_whole = DummyOperator(
    task_id='doris_jms_dwd__dwd_route_whole',
    pool='unlimited_pool',
    email=['zhangqinglin@jtexpress.com','yl_bigdata@yl-scm.com'],
    priority_weight=0,
    sla=timedelta(hours=18),
)

doris_jms_dwd__dwd_route_whole_from_whole_huanan << doris_jms_dwd__dwd_route_whole_from_whole_huabei
doris_jms_dwd__dwd_route_whole_from_whole_huadong << doris_jms_dwd__dwd_route_whole_from_whole_huazhong

doris_jms_dwd__route_whole << [
    dm__dm_route_whole_base_dt,
    doris_jms_dwd__dwd_route_whole_from_whole_dongbei,
    doris_jms_dwd__dwd_route_whole_from_whole_huabei,
    doris_jms_dwd__dwd_route_whole_from_whole_huadong,
    doris_jms_dwd__dwd_route_whole_from_whole_huanan,
    doris_jms_dwd__dwd_route_whole_from_whole_huaxi,
    doris_jms_dwd__dwd_route_whole_from_whole_huazhong,
    doris_jms_dwd__dwd_route_whole_from_whole_xibei,
    doris_jms_dwd__dwd_route_whole_from_whole_xinan,
    doris_jms_dwd__dwd_route_whole_from_local_city,
    # doris_jms_dwd__dwd_route_whole_from_whole_inbranch
]
